package com.yc.bigdata.kafka.bind;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * <p>MQ Streams Binding统一定义消息通道</p>
 *
 * @author: YuanChilde
 * @date: 2019-12-16 9:56
 * @version: 1.0
 * Modification History:
 * Date    Author      Version     Description
 * -----------------------------------------------------------------
 * 2019-12-16 9:56    YuanChilde     1.0        新增
 */
public interface KafkaStreamBinding {
    /**
     * 消息的发布通道名称
     */
    String TEST_OUTPUT = "outTest";
    /**
     * 消息的订阅通道名称
     */
    String TEST_INPUT = "inTest";

/*    @Input(TEST_INPUT)
    SubscribableChannel inTest();*/

    @Output(TEST_OUTPUT)
    MessageChannel outTest();
}
